package com.atguigu.day03;

import org.apache.flink.util.MathUtils;

public class Example3 {
    public static void main(String[] args) {
        Integer key = 2;
        int hashCode = key.hashCode();
        int murmurHash = MathUtils.murmurHash(hashCode);
        // 默认的最大并行度是128
        // reduce的并行度是4
        int idx = (murmurHash % 128) * 4 / 128;
        System.out.println(idx);
    }
}
